#if !defined(__APP_MQTT_H)
#define __APP_MQTT_H

#define ADDRESS     "ws://192.168.11.1:1883"
#define CLIENTID    "f9daa00d-3b84-4768-a714-1819a3df0c04"
#define TOPIC_PUSH       "push"
#define TOPIC_PULL      "pull"
#define QOS         1
#define TIMEOUT     10000L

/**
 * @breif 初始化MQTT客户端
 * @return 0:成功，-1:失败
 */
int app_mqtt_init();

/**
 * @breif 关闭MQTT客户端
 * @return 无
 */
void app_mqtt_close();

/**
 * @breif  向远程MQTT服务器发送消息数据
 * @param data:数据指针
 * @param len:数据长度
 * @return 0:成功，-1:失败
 */
int app_mqtt_sendMsg(char *data, int len);

/**
 * @breif 注册接收数据回调函数
 * @param callback:回调函数
 *          char *data:数据指针
 *          int len:数据长度
 * @return 无
 */
void app_mqtt_registerRecvCallback(int (*callback)(char *data, int len));

#endif // __APP_MQTT_H
